package com.ylkj.bus.dispatcher;

import com.ylkj.bus.MessageContent;
import com.ylkj.common.CustomSerializable;
import org.apache.flink.streaming.api.datastream.DataStream;

public interface  IStreamHandler extends CustomSerializable {
   void handle(DataStream<MessageContent> stream);
}
